curl -fsS https://hub.infinyon.cloud/install/install.sh | bash

fluvio cluster start
# fluvio cluster start --k8
# fluvio cluster start --k8 --proxy-addr 172.18.0.4:9003
fvm install sdf-beta7

sdf run --ui

fluvio produce sentence

fluvio hub smartmodule download infinyon/jolt@0.4.1
# 运行 HTTP 连接器
cdk hub download infinyon/http-source@0.3.8

cdk deploy start --ipkg infinyon-http-source-0.3.8.ipkg -c quotes-source-connector.yml

fluvio consume quotes
fluvio consume quotes --transforms-file transforms.yaml -T=2

# 创建数据管道
cdk deploy start --ipkg infinyon-http-source-0.3.8.ipkg -c string-quotes-source-connector.yml

# 查看连接器状态
cdk deploy list

fluvio consume string-quotes

cdk deploy shutdown --name http-quotes
cdk deploy shutdown --name string-quotes
fluvio topic delete quotes
fluvio topic delete string-quotes
fluvio topic delete quickstart-topic
# ----------------------------------------------------

# 主题镜像

fluvio topic create mirror-topic --mirror
fluvio topic add-mirror mirror-topic remote-raspberry
